fb290831dc49f0aa79ab69a4bde517f7bf6277e1,src/main/java/net/openhft/chronicle/queue/impl/single/SingleChronicleQueueStore.java,SingleChronicleQueueStore,writeMarshallable,#WireOut#,299
Before Change
if (lastAcknowledgedIndexReplicated == null)
lastAcknowledgedIndexReplicated = wire.newLongReference();
wire.write(MetaDataField.wireType).object(wireType)
.write(MetaDataField.roll).typedMarshallable(this.roll)
.write(MetaDataField.indexing).typedMarshallable(this.indexing)
.write(MetaDataField.lastAcknowledgedIndexReplicated)
.int64forBinding(-1L, lastAcknowledgedIndexReplicated);
wire.write(MetaDataField.recovery).typedMarshallable(recovery);
wire.write(MetaDataField.deltaCheckpointInterval).int32(this.deltaCheckpointInterval);
// contended
wire.padToCacheAlign()
.write(MetaDataField.writePosition).int64forBinding(0L, writePosition);
}
@Override
After Change
if (lastAcknowledgedIndexReplicated == null)
lastAcknowledgedIndexReplicated = wire.newLongReference();
wire.write(MetaDataField.wireType).object(wireType)
.padToCacheAlign().write(MetaDataField.writePosition).int64forBinding(0L, writePosition)
.write(MetaDataField.roll).typedMarshallable(this.roll)
.write(MetaDataField.indexing).typedMarshallable(this.indexing)
.write(MetaDataField.lastAcknowledgedIndexReplicated)
.int64forBinding(-1L, lastAcknowledgedIndexReplicated);